package org.example;


import com.alibaba.fastjson.JSONObject;
import org.example.rocket.Consumer;
import org.example.rocket.Producer;

public class Main {
    public static void main(String[] args) {
        try {
            //初始化生产者
            Producer.init();

            //构建数据内容消息体
            JSONObject jsonObject = new JSONObject();
            jsonObject.put("A1", 100);
            jsonObject.put("A2", 0.1);
            System.out.println("数据消息体内容：" + jsonObject.toJSONString());

            //发送消息
            Producer.send(jsonObject.toJSONString(),"ShuJu");

            //初始化消费者
            Consumer.init();

        }catch (Exception e){
            e.printStackTrace();
        }

    }
}